package com.shiqla.rabbit.controller;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;

/**
 * ━━━━━━神兽出没━━━━━━
 * 　　　┏┓　　　┏┓
 * 　　┏┛┻━━━┛┻┓
 * 　　┃　　　　　　　┃
 * 　　┃　　　━　　　┃
 * 　　┃　┳┛　┗┳　┃
 * 　　┃　　　　　　　┃
 * 　　┃　　　┻　　　┃
 * 　　┃　　　　　　　┃
 * 　　┗━┓　　　┏━┛
 * 　　　　┃　　　┃  神兽保佑
 * 　　　　┃　　　┃  代码无bug
 * 　　　　┃　　　┗━━━┓
 * 　　　　┃　　　　　　　┣┓
 * 　　　　┃　　　　　　　┏┛
 * 　　　　┗┓┓┏━┳┓┏┛
 * 　　　　　┃┫┫　┃┫┫
 * 　　　　　┗┻┛　┗┻┛
 * ━━━━━━感觉萌萌哒━━━━━━
 * Desc ${DESC}
 * Auth Administrator
 * Date 2018/7/11/011
 */
@Controller
@RequestMapping("rabbitmq")
public class LoginController {

    @Autowired
    private AmqpTemplate amqpTemplate;

    @RequestMapping(value = "/{name}/{address}/sendMsg.do", method = RequestMethod.POST)
    @ResponseBody
    public String sendMessage(@PathVariable(value = "name") String name,
                              @PathVariable(value = "address") String address,
                              @RequestParam(name = "message")String message) {

        String str = "rabbit.do test name " + name + "  address" + address;
       try {
           System.out.println(str);
           amqpTemplate.convertAndSend("topicExchange","topic.message",message);
       }catch (Exception e){
           e.printStackTrace();
       }
        return str;
    }
}
